package com.deep.flink.oceanbase;

import com.ververica.cdc.connectors.oceanbase.table.OceanBaseDeserializationSchema;
import com.ververica.cdc.connectors.oceanbase.table.OceanBaseRecord;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.util.Collector;

public class OceanBaseDeserializationSchemaImpl implements OceanBaseDeserializationSchema {
    @Override
    public TypeInformation getProducedType() {
        return null;
    }

    @Override
    public void deserialize(OceanBaseRecord oceanBaseRecord, Collector collector) throws Exception {

    }
}
